package mq

type Interface interface {
	Sub(topic, clientId string, fn func([]byte))   //订阅数据
	Pub(topic, clientId string, data []byte) error //发送数据
}

func New(op *Option) (Interface, error) {
	return NewClient(op)
}
